@Override
public void onNext(T t) {
if (sourceMode != ASYNC) {
queue.offer(t);
}
parent.drain();
}
@Override
public void onNext(T t) {
if (sourceMode != ASYNC) {
if (!queue.offer(t)) {
onError(Operators.onOperatorError(s, Exceptions.failWithOverflow("Queue is full?!"), t));
return;
}
}
parent.drain();
}